package com.invengo.module_check.ui.fragment.netmodel.utils;

import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;

public abstract class DownloadSubscriber<T>  implements Subscriber<T>  {
    /**
     * 分页每次同时请求数量
     */

    private static int REQUEST_VLUE = 1;;

    public static int getRequestVlue() {
        return REQUEST_VLUE;
    }

    public static void setRequestVlue(int requestVlue) {
        REQUEST_VLUE = requestVlue;
    }

    @Override
    public void onSubscribe(Subscription s) {
        s.request(REQUEST_VLUE);
    }

    @Override
    public void onError(Throwable t) {

    }

    @Override
    public void onComplete() {
        
    }
}
